package com.victor9ac.mashup.threadpool;


import com.victor9ac.mashup.api.MashupDataType;
import com.victor9ac.mashup.elasticsearch.tasks.ElasticSearchOperation;


public class MashupElasticSearchTask implements Runnable {

	
	private ElasticSearchOperation elasticSearchOperation;


	private Object obj;


	private MashupDataType mashupDataType;
	
	private String indexName;
	
	
	public MashupElasticSearchTask(ElasticSearchOperation elasticSearchOperation,MashupDataType mashupDataType,String indexName,Object obj) {
		super();
		this.elasticSearchOperation = elasticSearchOperation;
		this.mashupDataType = mashupDataType;
		this.indexName = indexName;
		this.obj = obj;

	}

	public void run() {
		
		elasticSearchOperation.setFromMyPersistence(obj, mashupDataType,indexName);
		
	}
	


}
